home *** CD-ROM | disk | FTP | other *** search
/ Developer CD Series 1998 January: Mac OS SDK / Dev.CD Jan 98 SDK1.toast / Development Kits (Disc 1) / AppleTalk Wide Area / XTI Shell Sample Code / XTIShell.c < prev    next >
Encoding:
C/C++ Source or Header  |  1993-02-17  |  35.1 KB  |  1,346 lines  |  [TEXT/MPS ]
  1. /*_________________________________________________________________________________
  2.  
  3.     File:        XTIShell.c
  4.     
  5.     This file contains the C routines called by XTIShell.a for the implementation 
  6.     of the AURP atlk calls.  It is based on the X25Tunnel atlk code and some X25 
  7.     specific things have been left in to provide an example.  Hints on things that 
  8.     may need to be changed are provided throughout.
  9.     
  10.     It is assumed that the implementation of XTI that the code was written to
  11.     (MacOSI) is standard enough that XTI specific changes will not need to be made.
  12.     This assumption has not yet been put to the test.  If you are not using MacOSI
  13.     or TII, be careful!
  14.     
  15.     Apple Computer, Inc. 
  16.     Copyright (C) 1992,1993.  All rights reserved.
  17.         
  18.     Revision History:
  19.     
  20. __________________________________________________________________________________*/
  21.  
  22. #include     <GestaltEqu.h>
  23. #include    <ToolUtils.h>
  24. #include    <String.h>
  25. #include    <Memory.h>
  26. #include    "AURPInterface.h"
  27. #include    "XTIShell.h"
  28. #include    "XTIShell_r.h"
  29.  
  30. /* ___ XTI flag bits ___ */
  31. #define        XTIInit                    0                        // bit 0, set if init'ed
  32. #define        XTIClose                1                        // bit 1, set if closing
  33. #define        XTILapInst                2                        // bit 2, set if LAP Write code is installed
  34.  
  35. /* ___ Log string indexes for our array ___ */
  36. #define        kDialLogIx                kDialLog-1        
  37. #define        kAnswerLogIx            kAnswerLog-1
  38. #define        kConnectLogIx            kConnectLog-1
  39. #define        kConnClearLogIx            kConnClearLog-1
  40. #define        kConnDownLogIx            kConnDownLog-1
  41. #define        kConnReqFailLogIx        kConnReqFailLog-1
  42. #define        kPasswordLogIx            kPasswordLog-1
  43.  
  44. //
  45. // This timer is used for both opening a connection and reconnecting.
  46. // You may eventually want to separate these timers, or put it in a resource
  47. // for fine tuning by you or the user if necessary.
  48. //
  49. /* ___ retry timer ___ */
  50. #define        kRetryTimer                10000                    // retry every 10 seconds
  51.  
  52. /* prototypes for the routines called from the assember code in XTIShell.a */
  53. OSErr    DOXTIINSTALL(XTIShellVarsPtr     myVarsPtr, XTIacfgPtr  aConfigPtr, TADEVSigRecPtr aSigPtr);
  54. OSErr    DOXTIDISCONNECT(XTIShellVarsPtr     myVarsPtr);
  55. OSErr    DOXTISHUTDOWN(XTIShellVarsPtr     myVarsPtr);
  56. OSErr     XTIWRITE(XTIShellVarsPtr myVarsPtr);
  57. OSErr     XTICONNECT(XTIShellVarsPtr myVarsPtr);
  58.  
  59. /* prototypes for the local routines */
  60. static void    do_try_open(void);
  61. static void    try_open(void);
  62. static int    try_reconnect( XTIShellVarsPtr myVarsPtr );
  63. static int    do_open( XTIShellVarsPtr myVarsPtr );
  64. static int    do_bind( XTIShellVarsPtr myVarsPtr );
  65. static void    do_connect( XTIShellVarsPtr myVarsPtr );
  66. static void    reconnect(void);
  67. static void    get_disconnect( XTIShellVarsPtr myVarsPtr );
  68. static void    doSendErr ( XTIShellVarsPtr myVarsPtr );
  69. static void    doReadErr ( XTIShellVarsPtr myVarsPtr );
  70. static void    get_data( XTIShellVarsPtr myVarsPtr );
  71. static void    get_connect( XTIShellVarsPtr myVarsPtr );
  72. static int    get_listen( XTIShellVarsPtr myVarsPtr );
  73. static void asyncReceive (int fd, int event, unsigned long providerInfo,int errno, void *cookie);
  74. static void    check_send( XTIShellVarsPtr myVarsPtr, int dataSent );
  75. static void Bin2Ascii(unsigned char *bin, unsigned char len, unsigned char *ascii);
  76. static XTIShellVarsPtr GETGLOBALS (void);
  77.  
  78. /*______________________________________________________________________________
  79.  
  80.     DOXTIINSTALL - Do the install.  Several modifications must be made in this
  81.                    routine.
  82.   
  83.     Returns:     error code
  84.     
  85.     Parameters:    --> myVarsPtr, aConfigPtr, aSigPtr
  86.     
  87. ______________________________________________________________________________*/
  88.  
  89. OSErr    DOXTIINSTALL(XTIShellVarsPtr    myVarsPtr, 
  90.                      XTIacfgPtr              aConfigPtr, 
  91.                      TADEVSigRecPtr     aSigPtr)
  92.  
  93. {
  94.     OSErr                result;
  95.     Ptr                    memBlockPtr;
  96.     char                i;
  97.     CShellGlobalsPtr    myGlobals;
  98.     long                ProcessorType;
  99.     ReOpenTMRecPtr        myReOpenTMRecPtr;
  100.     dtRecPtr            mydtRecPtr;
  101.     
  102.     
  103.     /* set up memcpy */
  104.     ProcessorType = gestalt68000;
  105.     result = Gestalt(gestaltProcessorType, &ProcessorType);
  106.     if (ProcessorType != gestalt68000)
  107.         memcpySetLongMove (ProcessorType);
  108.  
  109.     /* Get memory globals */
  110.     myVarsPtr->cGlobals = (CShellGlobalsPtr) GETSYSMEM(sizeof(CShellGlobals));
  111.     if (!myVarsPtr->cGlobals)
  112.         return(-1);
  113.     myGlobals = myVarsPtr->cGlobals;
  114.     
  115.     /* Get memory for log messages */
  116.     memBlockPtr = GETSYSMEM(kNumLogStr*kMaxLogStrLen);
  117.     if (!memBlockPtr)
  118.         return(-1);
  119.     
  120.     /* Get memory for time manager record */
  121.     myGlobals->openTMRec = (ReOpenTMRecPtr) GETSYSMEM (sizeof(ReOpenTMRec));
  122.     if (!myGlobals->openTMRec)
  123.         return(-1);
  124.     
  125.     /* Get memory for deferred task manager record */
  126.     myGlobals->mydtRec = (dtRecPtr) GETSYSMEM (sizeof(dtRec));
  127.     if (!myGlobals->mydtRec)
  128.         return(-1);
  129.     
  130.     /* initialize log string Ptrs */
  131.     for (i=0; i<kNumLogStr; i++) {
  132.         myGlobals->logStr[i] = memBlockPtr;
  133.         memBlockPtr += kMaxLogStrLen; 
  134.     }
  135.     
  136.     /* Get the log strings */
  137.     for (i=0; i< kNumLogStr; i++) {
  138.         GetIndString( (Str255) myGlobals->logStr[i], kXTILogStrID, i+1 );
  139.     }
  140.     
  141.     /* save config record */
  142.     myGlobals->theConfig = *aConfigPtr;
  143.             
  144.     /* initialize variables */
  145.     myGlobals->fd = -1;
  146.     myVarsPtr->otherNode = kNextIR;
  147. //
  148. // Fill in the appropriate line speed here.  If you don't know it until
  149. // the connection has been established, fill in your best guess and
  150. // put the correct information in later.
  151. //
  152.     myVarsPtr->lineSpeed = 9600;
  153.     myVarsPtr->OurSlotId = aSigPtr->slot;
  154.     myGlobals->bindComplete = false;
  155.     myGlobals->isConnected = false;
  156.     myGlobals->isReconnecting = false;
  157.     myGlobals->toldConnDone = false;
  158.     myGlobals->isFlowControlled = false;
  159.     myGlobals->isSending = false;
  160.     myGlobals->waitMoreData = false;
  161.     myVarsPtr->rcvBufAvail = true;
  162.     myVarsPtr->rcvPktsWaiting = 0;
  163.     myGlobals->waitForBind = false;
  164.     
  165. //
  166. // Fill in the maximum buffer size your link will allow here.  
  167. //
  168.     myVarsPtr->maxRPktSz = 618;
  169. //
  170. // The addressing scheme shown here is that of X.25.  This needs to be
  171. // changed to support the addressing scheme of the link you are using.
  172. //
  173.     myVarsPtr->remoteAddr[0] = 
  174.         myGlobals->theConfig.remoteAddr.ssaf.DTEaddr.X121Addr.len;
  175.     Bin2Ascii(myGlobals->theConfig.remoteAddr.ssaf.DTEaddr.X121Addr.addr,
  176.             myVarsPtr->remoteAddr[0],
  177.             &myVarsPtr->remoteAddr[1]);
  178.     
  179.     /* Get memory for receive  and send buffers */
  180.     myGlobals->sendBuffer = GETSYSMEM( myVarsPtr->maxRPktSz );
  181.     if (!myGlobals->sendBuffer) return(-1);
  182.     myGlobals->receiveBuffer = GETSYSMEM( myVarsPtr->maxRPktSz );
  183.     if (!myGlobals->receiveBuffer) return(-1);
  184.     
  185.     /* set up time manager variables for reconnect */
  186.     myGlobals->tmInfo.tmAddr = (TimerProcPtr) reconnect;
  187.     myGlobals->tmInfo.tmWakeUp = 0;
  188.     myGlobals->tmInfo.tmReserved = 0;
  189.     myGlobals->myA5 = GETMYA5();
  190.     
  191.     /* initialize deferred task manager record */
  192.     mydtRecPtr = myGlobals->mydtRec;
  193.     mydtRecPtr->qLink        = 0;
  194.     mydtRecPtr->qType         = dtQType;
  195.     mydtRecPtr->dtFlags        = 0;
  196.     mydtRecPtr->dtAddr         = (ProcPtr) try_open;
  197.     mydtRecPtr->dtParm         = 0;
  198.     mydtRecPtr->dtReserved     = 0;
  199.     
  200.     /* set up time manager variables for open */
  201.     myReOpenTMRecPtr = myGlobals->openTMRec;
  202.     myReOpenTMRecPtr->tmInfo.tmAddr = (TimerProcPtr) do_try_open;
  203.     myReOpenTMRecPtr->tmInfo.tmWakeUp = 0;
  204.     myReOpenTMRecPtr->tmInfo.tmReserved = 0;
  205.     
  206.     /* install time manager task */
  207.     if (myGlobals->theConfig.autoReconn) {
  208.         InsTime((QElemPtr) myGlobals);
  209.     }
  210.     InsTime((QElemPtr) myGlobals->openTMRec);
  211.             
  212.     return(0);
  213. } 
  214.  
  215.  
  216. /*______________________________________________________________________________
  217.     DOXTIDISCONNECT(XTIShellVarsPtr     myVarsPtr)
  218.     
  219.     Do the disconnect.   This code should not need any modifications.
  220.   
  221.     Returns:     error code
  222.     
  223.     Parameters:    --> myVarsPtr
  224. ______________________________________________________________________________*/
  225.  
  226. OSErr    DOXTIDISCONNECT(XTIShellVarsPtr     myVarsPtr)
  227.  
  228. {
  229.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  230.     
  231.     myGlobals->isConnected = false;
  232.     myGlobals->isReconnecting = false;
  233.     myGlobals->toldConnDone = false;
  234.     
  235.     /* cancel outstanding writes */
  236.     if(myGlobals->isSending) {
  237.         myGlobals->isSending = false;
  238.         (*myVarsPtr->AURPDispatch)(kAURPWriteDone, myVarsPtr->AURPRefNum, myVarsPtr->wDSPtr, -1);
  239.     }
  240.  
  241.     /*  close the connection, don't care about unbind */
  242.     if (myGlobals->fd != -1) {    
  243.         t_close (myGlobals->fd);
  244.         myGlobals->fd = -1;
  245.     }
  246.     
  247.     return (0);
  248. }
  249.  
  250. /*______________________________________________________________________________
  251.     DOXTISHUTDOWN - Do the shutdown.  This code should not need any modifications
  252.                     unless additional memeory was allocated at AInstall time.
  253.   
  254.     Returns:     error code
  255.     
  256.     Parameters:    --> myVarsPtr
  257.     
  258.     Note:    Only call link tool if port info var is non-zero.                        
  259. ______________________________________________________________________________*/
  260.  
  261. OSErr    DOXTISHUTDOWN(XTIShellVarsPtr     myVarsPtr)
  262.  
  263. {
  264.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  265.         
  266.     
  267.     /* Dispose the memory allocated in Install */
  268.     if (myVarsPtr->cGlobals) {
  269.     
  270.         if (myGlobals->theConfig.autoReconn && myGlobals->tmInfo.tmAddr) {
  271.             RmvTime((QElemPtr) myGlobals);
  272.         }
  273.         if(myGlobals->openTMRec->tmInfo.tmAddr)
  274.             RmvTime((QElemPtr) myGlobals->openTMRec);
  275.             
  276.         if (myGlobals->sendBuffer)
  277.             DisposPtr(myGlobals->sendBuffer);
  278.         if (myGlobals->receiveBuffer)
  279.             DisposPtr(myGlobals->receiveBuffer);
  280.         if (myGlobals->logStr[0])
  281.             DisposPtr(myGlobals->logStr[0]);
  282.         if (myGlobals->openTMRec)
  283.             DisposPtr((Ptr)myGlobals->openTMRec);
  284.             
  285.         DisposPtr((Ptr)myVarsPtr->cGlobals);
  286.         myVarsPtr->cGlobals = 0;
  287.     }
  288.     
  289.     return(noErr);
  290. }
  291.  
  292. /*____________________________________________________________________________
  293.     XTIWRITE (XTIShellVarsPtr myVarsPtr)
  294.     
  295.     Take a WDS element and write it out with t_snd.  This code should not need
  296.     any modification.
  297.     
  298.     Returns:    error code
  299.     
  300.     Parameters:    --> myVarsPtr
  301. ______________________________________________________________________________*/
  302.  
  303. OSErr XTIWRITE(XTIShellVarsPtr myVarsPtr)
  304. {
  305.     OSErr                error;
  306.     int                    event;
  307.     Ptr                    tempBuffer;
  308.     short                 i;
  309.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  310.     
  311. //
  312. // If we are connected and not sending and the WDS element sent is not empty,
  313. // write out the packect.
  314. //
  315.     if(myGlobals->isConnected 
  316.         && !myGlobals->isSending
  317.         && myVarsPtr->wDSPtr[0].entryLength != 0) {
  318.         
  319.         /* copy wds element to send buffer */
  320.         myGlobals->sendBuffLen = 0;
  321.         tempBuffer = myGlobals->sendBuffer;
  322.         for(i = 0; myVarsPtr->wDSPtr[i].entryLength; i++) {
  323.             if (myGlobals->sendBuffLen+myVarsPtr->wDSPtr[i].entryLength > myVarsPtr->maxRPktSz) {
  324.                 return(-1);
  325.             }
  326.             memcpy (tempBuffer, myVarsPtr->wDSPtr[i].entryPtr, myVarsPtr->wDSPtr[i].entryLength);
  327.             myGlobals->sendBuffLen += myVarsPtr->wDSPtr[i].entryLength;
  328.             tempBuffer += myVarsPtr->wDSPtr[i].entryLength;
  329.         }
  330.         
  331.         /* now send the data */
  332.         myGlobals->isSending = true;
  333.         myGlobals->dataToSendPtr = myGlobals->sendBuffer;
  334.         error = t_snd( myGlobals->fd, myGlobals->dataToSendPtr, myGlobals->sendBuffLen, 0 );
  335.         if (error) {
  336.             /* check error */
  337.             switch (t_ERRNO( myGlobals->fd ))
  338.             {
  339.                 case TFLOW:
  340.                     myGlobals->isFlowControlled = true;
  341.                     break;
  342.                     
  343.                 case TLOOK:
  344.                     event = t_look ( myGlobals->fd ) ;
  345.                     if (event == T_DISCONNECT)
  346.                     {
  347.                         get_disconnect( myVarsPtr );
  348.                     }
  349.                     else doSendErr( myVarsPtr );    
  350.                     break;
  351.                     
  352.                 default:
  353.                     doSendErr( myVarsPtr );    
  354.                     break;
  355.                     
  356.             }
  357.         }
  358.         
  359.     }
  360.     else{
  361.         return( -1 );
  362.     }
  363.     
  364.     return( noErr );
  365.     
  366. }
  367.                 
  368.             
  369.  
  370.  
  371. /*____________________________________________________________________________
  372.     XTICONNECT (XTIShellVarsPtr myVarsPtr)
  373.     
  374.     This routine logs that we are trying to connect and sets up a time manager
  375.     task that will actually do the open.  This code should not need any
  376.     modifications.
  377.     
  378.     Returns:    error code
  379.     
  380.     Parameters:    --> myVarsPtr
  381. ______________________________________________________________________________*/
  382.  
  383. OSErr XTICONNECT(XTIShellVarsPtr myVarsPtr)
  384. {
  385.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  386.     
  387.     
  388.     /* Log that we're initiating the connection */
  389.     if (myGlobals->theConfig.isCalling) 
  390.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kDialLogIx]);
  391.     else
  392.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kAnswerLogIx]);
  393.         
  394.     PrimeTime((QElemPtr) myGlobals->openTMRec, kRetryTimer);
  395.     
  396.     return( 0 );
  397. }
  398.  
  399. /*____________________________________________________________________________
  400.     do_try_open (void)
  401.     
  402.     This routine is called by the Time Manager (installed at connect time).  It
  403.     sets up a deferred task to try the t_open.  This code should not need any 
  404.     modifications.
  405.     
  406. ______________________________________________________________________________*/
  407. static void 
  408. do_try_open (void)
  409. {
  410.     OSErr                error;
  411.     XTIShellVarsPtr     myVarsPtr = GETGLOBALS();
  412.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  413.     long                oldA5;
  414.  
  415.     oldA5 = GETMYA5();
  416.     SETMYA5(myGlobals->myA5);
  417.     
  418.     if ((error = DTInstall ((QElemPtr) myGlobals->mydtRec)) != noErr)
  419.         DebugStr ("\p Deferred Task Manager Returned Error");
  420.     
  421.     SETMYA5(oldA5);
  422.  
  423. }
  424.  
  425. /*____________________________________________________________________________
  426.     try_open (XTIShellVarsPtr myVarsPtr)
  427.     
  428.     This is the deferred task which does all the work for the connect sequence
  429.     (open, bind, connect).  Currently, it will continue to install itself (via 
  430.     the Time Manager routine) forever.  A suggestion for modification would be 
  431.     to set up a retry counter and limit the number of retries.
  432.  
  433. ______________________________________________________________________________*/
  434. static void
  435. try_open(void)
  436. {
  437.     XTIShellVarsPtr     myVarsPtr = GETGLOBALS();
  438.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  439.     long                oldA5;
  440.     
  441.     oldA5 = GETMYA5();
  442.     SETMYA5(myGlobals->myA5);
  443.     
  444.         
  445. //
  446. // If waitForBind is true, we have already successfully opened an endpoint
  447. // and are waiting for a T_BINDCOMPLETE event.  Just check the bindComplete 
  448. // flag.  If it is true, we are done, otherwise, set up the time manager to
  449. // call us again.
  450. //
  451.     if(myGlobals->waitForBind) {
  452.         if(!myGlobals->bindComplete) {
  453.             PrimeTime((QElemPtr) myGlobals->openTMRec, kRetryTimer);
  454.             SETMYA5(oldA5);
  455.             return;
  456.         }
  457.         
  458.         myGlobals->waitForBind = false;
  459.         
  460. //
  461. // If the bind is complete, check if there was a bind error.  If there was,
  462. // disconnect and tell AURP we did not connect successfully.
  463. //
  464.         if(myGlobals->bindErr) {
  465.             DOXTIDISCONNECT(myVarsPtr);
  466.             SETMYA5(oldA5);
  467.             CONNDONE( -1 );
  468.             return;
  469.         }
  470.     }
  471.  
  472. //
  473. // If the open has not been successfully completed, try it.
  474. //
  475.     if(myGlobals->fd == -1) {
  476.         if(do_open(myVarsPtr)) {
  477.             PrimeTime((QElemPtr) myGlobals->openTMRec, kRetryTimer);    
  478.             SETMYA5(oldA5);
  479.             return;
  480.         }
  481.     }
  482.  
  483. //
  484. // The open has completed successfully, if the bind hasn't completed, try it.
  485. //
  486.     if(!myGlobals->bindComplete) {
  487.         if(do_bind(myVarsPtr)) {
  488. //
  489. // if the bind fails immediately, close the endpoint so we can try again
  490. //
  491.                 t_close(myGlobals->fd);
  492.                 myGlobals->fd = -1;
  493.             }
  494.         else {
  495. //
  496. // Because we are called by the time manager we have to leave the routine 
  497. // to allow for the T_BINDCOMPLETE event to be called.    
  498. //
  499.             myGlobals->waitForBind = true;
  500.         }
  501.         PrimeTime((QElemPtr) myGlobals->openTMRec, kRetryTimer);
  502.         SETMYA5(oldA5);
  503.         return;
  504.     }
  505.         
  506. //
  507. // The bind and open are complete.  If we are the calling router,
  508. // issue the connect.
  509. //
  510.     if (myGlobals->theConfig.isCalling) {
  511.         do_connect(myVarsPtr);
  512.     }
  513.     
  514.             
  515.     SETMYA5(oldA5);
  516.     return;
  517. }
  518.  
  519.  
  520. /*____________________________________________________________________________
  521.     try_reconnect (XTIShellVarsPtr myVarsPtr)
  522.     
  523.     If the user configuration specified automatic reconnection, install the
  524.     Time Manager routine to reconnect.    This code should not need any 
  525.     modifications.
  526.     
  527.     Returns:    error code
  528.     
  529.     Parameters: myVarsPtr
  530. ______________________________________________________________________________*/
  531. static int
  532. try_reconnect( XTIShellVarsPtr myVarsPtr )
  533. {
  534.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  535.     
  536.         
  537.     if (myGlobals->theConfig.autoReconn) {
  538.         myGlobals->isReconnecting = true;
  539. //
  540. // If we are the calling router, delay the connect momentarily
  541. // to give the answering side a chance to start listening
  542. //
  543.         if (myGlobals->theConfig.isCalling)  {
  544.             PrimeTime((QElemPtr) myGlobals, kRetryTimer);
  545.         }
  546.         else {
  547.             return(XTICONNECT(myVarsPtr));
  548.         }
  549.     }
  550.     else {
  551.         DOXTIDISCONNECT(myVarsPtr);
  552.         return(-1);
  553.     }
  554.     
  555.     return(0);
  556. }
  557.  
  558.  
  559. /*____________________________________________________________________________
  560.     do_open (XTIShellVarsPtr myVarsPtr)
  561.     
  562.     This routine is called from the try_open routine.  It attempts a t_open. 
  563.     The slot ID is used as the provider name.  You may want to change this.
  564.     
  565.     Returns:    error code
  566.     
  567.     Parameters: myVarsPtr
  568. ______________________________________________________________________________*/
  569. static int
  570. do_open( XTIShellVarsPtr myVarsPtr )
  571. {
  572.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  573.     struct t_info        info;
  574.     char                providerName[2];
  575.     
  576.  
  577. //
  578. // Set up and call the t_open.  This will be a non blocking endpoint.  
  579. // Unless absolutely necessary, it should be left non blocking.
  580. //
  581.     providerName[0] = 0;
  582.     providerName[1] = myVarsPtr->OurSlotId;
  583.     myGlobals->fd = t_open(providerName, O_NONBLOCK, &info );
  584.     if (myGlobals->fd == -1) {
  585.         return(-1);
  586.     }
  587.         
  588. //
  589. // Install the notifier completion routine.
  590. //
  591.     if (t_install_notifier (myGlobals->fd, asyncReceive, myVarsPtr)) 
  592.         return(-1);
  593.         
  594. //
  595. // By setting bindComplete to false, we are assured the bind will be
  596. // attempted on returning to the try_open routine.
  597. //
  598.     myGlobals->bindComplete = false;
  599.         
  600.     
  601.     return(0);
  602. }
  603.  
  604.  
  605. /*____________________________________________________________________________
  606.     do_bind (XTIShellVarsPtr myVarsPtr)
  607.     
  608.     This routine is called from the try_open routine after the t_open is 
  609.     complete.  It attempts a t_bind.  X.25 specific addressing is used and will 
  610.     need to changed.
  611.  
  612.     Returns:    error code
  613.     
  614.     Parameters: myVarsPtr
  615. ______________________________________________________________________________*/
  616. static int
  617. do_bind( XTIShellVarsPtr myVarsPtr )
  618. {
  619.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  620.     struct     t_bind        bindRequest;
  621.     
  622.     bindRequest.addr.maxlen = sizeof(TTSAP);
  623.     bindRequest.addr.len =  sizeof(TTSAP);
  624.     bindRequest.addr.buf =  (char*) &myGlobals->theConfig.localAddr;
  625.     bindRequest.qlen = myGlobals->theConfig.isCalling ? 0 : 1;
  626.     
  627.     if (t_bind( myGlobals->fd, &bindRequest, nil ))
  628.         return(-1);
  629.     
  630.     return(0);
  631. }
  632.  
  633.  
  634. /*____________________________________________________________________________
  635.     do_connect (XTIShellVarsPtr myVarsPtr)
  636.     
  637.     This routine is called from the try_open routine after the open and bind are
  638.     complete.  It is called only if we are the calling router.  There is
  639.     X.25 specific address information here which will need to be modified.
  640.     
  641.     Returns:
  642.     
  643.     Parameters: myVarsPtr
  644. ______________________________________________________________________________*/
  645. static void
  646. do_connect( XTIShellVarsPtr myVarsPtr )
  647. {
  648.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  649.     struct t_call        sndcall;
  650.     OSErr                error = noErr;
  651.     
  652. //
  653. // Set up the t_call structure.  Put in the correct address
  654. // for your particular link type.
  655. //
  656.     sndcall.addr.maxlen = sizeof(TTSAP);
  657.     sndcall.addr.len = sizeof(TTSAP);
  658.     sndcall.addr.buf =  (char*) &myGlobals->theConfig.remoteAddr;
  659.     sndcall.opt.maxlen = 0;
  660.     sndcall.opt.len = 0;
  661.     sndcall.udata.maxlen = 0;
  662.     sndcall.udata.len = 0;
  663.         
  664. //
  665. // Make the t_connect call.  It will return -1 since we are asynchronous
  666. //
  667.     t_connect( myGlobals->fd, &sndcall, nil ) ;
  668. //
  669. // Check the actual error
  670. //
  671.     error = t_ERRNO( myGlobals->fd );
  672.     if(error != TNODATA)  {    
  673. //
  674. // If a T_NODATA error occurred, we are stuck.  Log the connection not
  675. // established message, disconnect, and tell AURP the connection failed.
  676. //
  677.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnReqFailLogIx]);
  678.         DOXTIDISCONNECT(myVarsPtr);
  679.         CONNDONE( -1 );
  680.     }
  681.  
  682. }
  683.  
  684.  
  685. /*____________________________________________________________________________
  686.     reconnect (void)
  687.     
  688.     The Time Manager reconnect routine.  Installed by try_reconnect routine
  689.     which is called whenever we think the connection has dropped and we
  690.     want to attempt to reconnect.  This code should not need any modifications.
  691.     
  692.     Returns:
  693.     
  694.     Parameters: 
  695. ______________________________________________________________________________*/
  696. static void
  697. reconnect(void)
  698. {
  699.     XTIShellVarsPtr     myVarsPtr = GETGLOBALS();
  700.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  701.     long                oldA5;
  702.     
  703.     oldA5 = GETMYA5();
  704.     SETMYA5(myGlobals->myA5);
  705.     
  706.             
  707.     if(XTICONNECT(myVarsPtr))  {
  708.         CONNDONE( -1 );
  709.     }
  710.     
  711.     SETMYA5(oldA5);
  712.  
  713. }
  714.  
  715.  
  716. /*____________________________________________________________________________
  717.     get_disconnect (XTIShellVarsPtr myVarsPtr)
  718.     
  719.     A disconnect event has been received on the endpoint, go get it.  This 
  720.     code should not need any modifications.
  721.     
  722.     Returns:    error code
  723.     
  724.     Parameters: myVarsPtr
  725. ______________________________________________________________________________*/
  726. static void
  727. get_disconnect( XTIShellVarsPtr myVarsPtr )
  728. {
  729.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  730.     struct t_discon        myDisconnect;
  731.     
  732.     
  733.     myDisconnect.udata.maxlen = 0;
  734.     myDisconnect.udata.buf = nil;
  735.     myDisconnect.udata.len = 0;
  736.     myDisconnect.reason = 0;
  737.     myDisconnect.sequence = 0;
  738.  
  739. //
  740. // Receive the disconnect event.  We don't care what the error
  741. // returned is because we are going to disconnect anyway.
  742. //
  743.     t_rcvdis( myGlobals->fd, &myDisconnect );    
  744.  
  745. //
  746. // If we were connected, log the connection went down message, otherwise log
  747. // the connection request refused message.
  748. //
  749.     if (myGlobals->isConnected)
  750.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  751.     else {    
  752.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnClearLogIx]);
  753.     }
  754.     myGlobals->isConnected = false;
  755.     
  756. //
  757. // Complete the disconnect
  758. //
  759.     DOXTIDISCONNECT(myVarsPtr);
  760. //
  761. // Attempt to reconnect
  762. //
  763.     if (try_reconnect(myVarsPtr))  {
  764.         CONNDONE( -1 );
  765.     }
  766. }
  767.  
  768. /*____________________________________________________________________________
  769.     doSendErr (XTIShellVarsPtr myVarsPtr)
  770.     
  771.     This routine is called when a send error occurs.  Assume the connection
  772.     has gone down.  This code should not need any modifications.
  773.     
  774.     Returns:
  775.     
  776.     Parameters: myVarsPtr
  777. ______________________________________________________________________________*/
  778. static void
  779. doSendErr ( XTIShellVarsPtr myVarsPtr )
  780. {
  781.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  782.  
  783. //
  784. // Log that the connection went down and complete disconnection
  785. //
  786.     (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  787.     DOXTIDISCONNECT(myVarsPtr);
  788. //
  789. // Attempt to reconnect
  790. //
  791.     if(try_reconnect(myVarsPtr)) 
  792.         CONNDONE( -1 );
  793.     
  794. }
  795.  
  796. /*____________________________________________________________________________
  797.     doReadErr (XTIShellVarsPtr myVarsPtr)
  798.     
  799.     This routine is called when a read error occurs.  Assume the connection 
  800.     went down.  This code should not need any modifications.
  801.     
  802.     Returns:
  803.     
  804.     Parameters: myVarsPtr
  805. ______________________________________________________________________________*/
  806. static void
  807. doReadErr ( XTIShellVarsPtr myVarsPtr )
  808. {
  809.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  810.  
  811. //
  812. // Log that the connection went down and complete disconnection
  813. //
  814.     (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  815.     DOXTIDISCONNECT(myVarsPtr);
  816.  
  817. //
  818. // Attempt to reconnect
  819. //
  820.     if(try_reconnect(myVarsPtr)) 
  821.         CONNDONE( -1 );
  822.     
  823. }
  824.     
  825.  
  826.  
  827. /*____________________________________________________________________________
  828.     READDONE (XTIShellVarsPtr myVarsPtr)
  829.     
  830.     This routine is called from assembly when the read buffer is returned from
  831.     AURP.  It is only called if data is outstanding.  This code should not need 
  832.     any modifications.
  833.     
  834.     Returns:
  835.     
  836.     Parameters:    myVarsPtr
  837. ______________________________________________________________________________*/
  838. void
  839. READDONE( XTIShellVarsPtr myVarsPtr )
  840. {
  841. //
  842. // Decrement the number of packets waiting to be read and get the data
  843. //
  844.     myVarsPtr->rcvPktsWaiting--;
  845.     get_data( myVarsPtr );
  846. }
  847.     
  848.  
  849.  
  850. /*____________________________________________________________________________
  851.     get_data (XTIShellVarsPtr myVarsPtr)
  852.     
  853.     This routine is called to get data that is waiting to be read.  This data 
  854.     is not necessarily a complete packet.  It is called by READDONE and when a 
  855.     T_DATA event is received.  This code should not need any modifications.
  856.     
  857.     Returns:
  858.     
  859.     Parameters:    myVarsPtr
  860. ______________________________________________________________________________*/
  861. static void
  862. get_data( XTIShellVarsPtr myVarsPtr )
  863. {
  864.     int                    bytesRead;
  865.     int                    flags;
  866.     Boolean                gotEndOfBuffer = false;
  867.     char                *buf;
  868.     OSErr                error = noErr;
  869.     int                    event;
  870.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  871.     long                sr;
  872.     
  873.     buf = myGlobals->receiveBuffer;
  874. //
  875. // If we are in waitMoreData state, the receiveBuffer is "empty"
  876. //
  877.     if (!myGlobals->waitMoreData) {
  878.         myGlobals->rcvBuffLen = 0;
  879.         myVarsPtr->rcvBufAvail = false;  /* flag is cleared in the assembler routine */
  880.     }
  881.     else {
  882.         myGlobals->waitMoreData = false;
  883.     }
  884.     
  885. //
  886. // Read until we get a complete packet or there is no more data to be read
  887. //
  888.     while(!error && !gotEndOfBuffer) {
  889.         flags = 0;
  890.         bytesRead = t_rcv( myGlobals->fd, &(buf[myGlobals->rcvBuffLen]), 
  891.                            myVarsPtr->maxRPktSz - myGlobals->rcvBuffLen, &flags );
  892. //
  893. // bytesRead equal to -1 indicates an error, find out what it is
  894. //
  895.         if (bytesRead == -1) {
  896.             error = t_ERRNO( myGlobals->fd );
  897.         }
  898.         else {
  899.             myGlobals->rcvBuffLen += bytesRead;
  900. //
  901. // If we have received more than we asked for, we have serious problems,
  902. // so tear down the connection
  903. //
  904.             if (myGlobals->rcvBuffLen > myVarsPtr->maxRPktSz)  {
  905.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  906.                 DOXTIDISCONNECT(myVarsPtr);
  907.                 CONNDONE( -1 );
  908.                 return;
  909.             }
  910. //
  911. // If the T_MORE flag isn't set, the packet is complete
  912. //
  913.             if (!(flags & T_MORE)) 
  914.                 gotEndOfBuffer = true;
  915.         } 
  916.     }
  917.     
  918. //
  919. // If we got the whole buffer, save the interrupt level and
  920. // give the buffer to AURP.  
  921. //
  922.     if (gotEndOfBuffer) {
  923.         sr = GETSR ();
  924.         (*myVarsPtr->AURPDispatch)(kAURPRead, myVarsPtr->AURPRefNum, 
  925.                                      myVarsPtr->otherNode, myGlobals->rcvBuffLen, buf);
  926.     }
  927.     
  928. //
  929. // If there was an error, check it and take appropriate action.
  930. //
  931.     if (error) {
  932.             switch (error)
  933.             {
  934.                 case TNODATA:
  935. //
  936. // This is the case where we did not receive the complete packet
  937. // so we still have a partial buffer.
  938. //
  939.                     myGlobals->waitMoreData = true;
  940.                     break;
  941.                     
  942.                 case TLOOK:
  943.                     event = t_look ( myGlobals->fd ) ;
  944.                     if (event == T_DISCONNECT)
  945.                     {
  946.                         get_disconnect( myVarsPtr );
  947.                     }
  948.                     else doReadErr( myVarsPtr );
  949.                     return;
  950.                 default:
  951.                     doReadErr( myVarsPtr );    
  952.                     return;
  953.             }
  954.         }
  955.     
  956.     return;
  957. }
  958.  
  959. /*____________________________________________________________________________
  960.     get_connect (XTIShellVarsPtr myVarsPtr)
  961.     
  962.     This routine is called when a T_CONNECT event is received.  Go get the
  963.     connect.  This code should not need any modifications.
  964.     
  965.     Returns:
  966.     
  967.     Parameters:    myVarsPtr
  968. ______________________________________________________________________________*/
  969. static void
  970. get_connect( XTIShellVarsPtr myVarsPtr )
  971. {
  972.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  973.     
  974.  
  975.     if (t_rcvconnect( myGlobals->fd, nil ))
  976.     {
  977. //
  978. // If an error occurred on the receive connect, log
  979. // the connection not established message, disconnect,
  980. // and tell AURP the connection failed.
  981. //
  982.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnReqFailLogIx]);
  983.         DOXTIDISCONNECT(myVarsPtr);
  984.         if(try_reconnect(myVarsPtr)) 
  985.             CONNDONE( -1 );
  986.             return;
  987.     } else {
  988.         myGlobals->isConnected = true;
  989.     
  990. //
  991. // Log the connection established message and tell AURP
  992. // the connection was successful.
  993. //
  994.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnectLogIx]);
  995.         if(!myGlobals->toldConnDone) {
  996.             CONNDONE( 0 );
  997.             myGlobals->toldConnDone = false;
  998.         }
  999.             
  1000.         myGlobals->isReconnecting = false;
  1001.     }    
  1002. }
  1003.  
  1004. /*____________________________________________________________________________
  1005.     get_listen (XTIShellVarsPtr myVarsPtr) 
  1006.     
  1007.     This routine is called when a T_LISTEN event occurs.  If password
  1008.     protection is desired, code should be added to verify it before
  1009.     accepting the connection.
  1010.     
  1011.     Returns:    error code
  1012.     
  1013.     Parameters: myVarsPtr
  1014. ______________________________________________________________________________*/
  1015. static int
  1016. get_listen( XTIShellVarsPtr myVarsPtr )
  1017. {
  1018.     struct t_call        call;
  1019.     CShellGlobalsPtr    myGlobals = myVarsPtr->cGlobals;
  1020.     
  1021.     
  1022.     call.addr.buf =   (char*) &myGlobals->theConfig.remoteAddr;
  1023.     call.addr.maxlen = sizeof(TTSAP);
  1024.     call.opt.buf = nil;
  1025.     call.udata.maxlen = 0;
  1026.     call.udata.buf = nil;
  1027.     
  1028. //
  1029. // Get the listen event.  If we fail to get it, log connection down,
  1030. // disconnect, and try to reconnect.
  1031. //
  1032.     if (t_listen( myGlobals->fd, &call ))
  1033.     {       
  1034.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1035.         DOXTIDISCONNECT(myVarsPtr);
  1036.         return( try_reconnect(myVarsPtr) );
  1037.  
  1038.     }
  1039.         
  1040. //
  1041. // Accept the connection.
  1042. //
  1043.     if ( t_accept(myGlobals->fd, myGlobals->fd, &call ) )
  1044.     {    
  1045. //
  1046. // If an error occurs on the t_accept, log connection down, disconnect,
  1047. // and try to reconnect.
  1048. //
  1049.         (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1050.         DOXTIDISCONNECT(myVarsPtr);
  1051.         return( try_reconnect(myVarsPtr) );
  1052.     }
  1053.     
  1054.     return(0);
  1055.     
  1056. }
  1057.  
  1058. /*____________________________________________________________________________
  1059.     check_send ( XTIShellVarsPtr myVarsPtr, int dataSent )
  1060.     
  1061.     This routine is called when a T_SENDCOMPLETE event occurs.  Check
  1062.     the results and act accordingly.  This code should not need any
  1063.     modifications.
  1064.     
  1065.     Returns:
  1066.     
  1067.     Parameters:    myVarsPtr,    dataSent
  1068. ______________________________________________________________________________*/
  1069.  
  1070. static void    check_send( XTIShellVarsPtr myVarsPtr, int dataSent ) {
  1071.     CShellGlobalsPtr    myGlobals;
  1072.     int                    event;
  1073.     
  1074.     
  1075.     myGlobals = myVarsPtr->cGlobals;
  1076.  
  1077. //
  1078. // If the dataSent is less than the buffer length, all the
  1079. // data was not sent so send the rest of it.
  1080. //
  1081.         if (dataSent < myGlobals->sendBuffLen) 
  1082.         {
  1083.             myGlobals->sendBuffLen -= dataSent;
  1084.             myGlobals->dataToSendPtr += dataSent;
  1085.             if (t_snd( myGlobals->fd, myGlobals->dataToSendPtr, myGlobals->sendBuffLen, 0 )) {
  1086. //
  1087. // If the t_snd failed, find out why.
  1088. //
  1089.                 switch (t_ERRNO( myGlobals->fd ))
  1090.                 {
  1091.                     case TFLOW:
  1092.                         myGlobals->isFlowControlled = true;
  1093.                         break;
  1094.                         
  1095.                     case TLOOK:
  1096.                         event = t_look ( myGlobals->fd ) ;
  1097.                         if (event == T_DISCONNECT)
  1098.                         {
  1099.                             get_disconnect( myVarsPtr );
  1100.                         }
  1101.                         else doSendErr( myVarsPtr );    
  1102.                         break;
  1103.                         
  1104.                     default:
  1105.                         doSendErr( myVarsPtr );    
  1106.                         break;
  1107.                         
  1108.                 }
  1109.             }
  1110.         }
  1111.         else 
  1112.         {
  1113. //
  1114. // All the data was successfully sent.  Tell AURP the write
  1115. // is complete.
  1116. //
  1117.             myGlobals->isSending = false;
  1118.             (*myVarsPtr->AURPDispatch)(kAURPWriteDone, myVarsPtr->AURPRefNum, myVarsPtr->wDSPtr, 0);
  1119.         }
  1120.             
  1121. }
  1122.  
  1123. /*____________________________________________________________________________
  1124.     AsyncReceive (int fd, int event, unsigned long providerInfo,
  1125.                                         int errno, void *cookie)
  1126.                         
  1127.     This is the installed completion routine.  All XTI events are processed 
  1128.     here.  The procedure for each event is basically the same - if there
  1129.     was an error, log a connection down error message, disconnect, and tell
  1130.     AURP.  Otherwise, call a routine to handle the event.  This routine should 
  1131.     not need to be modified unless you want to perform different or
  1132.     additional error handling.
  1133.     
  1134.     Returns:
  1135.     
  1136.     Parameters:    fd, event, providerInfo, errNo, -> cookie
  1137. ______________________________________________________________________________*/
  1138.  
  1139. static void asyncReceive (int fd, int event, unsigned long providerInfo,
  1140.                                             int errno, void *cookie)
  1141. {
  1142. #pragma unused (providerInfo)
  1143.     XTIShellVarsPtr        myVarsPtr;
  1144.     CShellGlobalsPtr    myGlobals;
  1145.     
  1146.     
  1147.  
  1148.     myVarsPtr = (XTIShellVarsPtr) cookie;
  1149.     myGlobals = myVarsPtr->cGlobals;
  1150.         
  1151.     switch (event)
  1152.     {
  1153.         case T_BINDCOMPLETE:
  1154. //
  1155. // An outstanding bind request has completed
  1156. //
  1157.             myGlobals->bindComplete = true;
  1158.             myGlobals->bindErr = errno;
  1159.             if(errno) {
  1160.                 break;
  1161.             }
  1162.             myGlobals->bindErr = t_rcvbind (fd, nil);
  1163.             if(myGlobals->bindErr) {
  1164.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnReqFailLogIx]);
  1165.                 break;
  1166.             }
  1167.             break;
  1168.             
  1169.         case T_CONNECT:
  1170. //
  1171. // You are the calling router and a connect response
  1172. // to your connect request has been received.
  1173. //
  1174.             if (errno)
  1175.             {        
  1176.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1177.                 DOXTIDISCONNECT(myVarsPtr);
  1178.                 if(try_reconnect(myVarsPtr)) 
  1179.                     CONNDONE( -1 );
  1180.                 break;
  1181.             }
  1182.             
  1183.             get_connect( myVarsPtr );
  1184.             
  1185.             break;
  1186.             
  1187.         case T_DISCONNECT:
  1188. //
  1189. // A router is trying to disconnect
  1190. //
  1191.             if (errno) {
  1192.                 DOXTIDISCONNECT(myVarsPtr);
  1193.                 if(try_reconnect(myVarsPtr)) 
  1194.                     CONNDONE( -1 );
  1195.                 break;
  1196.             }
  1197.             
  1198.             get_disconnect( myVarsPtr );
  1199.             
  1200.             break;
  1201.             
  1202.         case T_PASSCON:
  1203. //
  1204. // You are the answering router and the connection you accepted
  1205. // is now complete.
  1206. //
  1207.             if (errno)
  1208.             {        
  1209.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1210.                 DOXTIDISCONNECT(myVarsPtr);
  1211.                 if(try_reconnect(myVarsPtr)) 
  1212.                     CONNDONE( -1 );
  1213.                 break;
  1214.             }
  1215.                         
  1216.             myGlobals->isConnected = true;
  1217.             // log connection established message
  1218.             (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnectLogIx]);
  1219.  
  1220.             if(!myGlobals->toldConnDone) {
  1221.                 CONNDONE( 0 );
  1222.                 myGlobals->toldConnDone = false;
  1223.             }
  1224.             myGlobals->isReconnecting = false;    
  1225.             
  1226.         case T_GODATA:
  1227. //
  1228. // The connection was flow controlled, but now it is not.
  1229. //
  1230.             if (errno == -1)
  1231.             {        
  1232.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1233.                 DOXTIDISCONNECT(myVarsPtr);
  1234.                 if(try_reconnect(myVarsPtr)) 
  1235.                     CONNDONE( -1 );
  1236.                 break;
  1237.             }
  1238.             
  1239. //
  1240. // T_GODATA is the same as T_SENDCOMPLETE, only 0 bytes are sent 
  1241. //
  1242.             myGlobals->isFlowControlled = false;
  1243.             errno = 0;
  1244. //
  1245. // continue with the code for T_SENDCOMPLETE 
  1246. //
  1247.             
  1248.         case T_SENDCOMPLETE:
  1249. //
  1250. // A outstanding send is complete
  1251. //
  1252.             if (errno == -1)
  1253.             {        
  1254.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1255.                 DOXTIDISCONNECT(myVarsPtr);
  1256.                 if(try_reconnect(myVarsPtr)) 
  1257.                     CONNDONE( -1 );
  1258.                 break;
  1259.             }
  1260.             
  1261.             check_send(myVarsPtr, errno);
  1262.             break;
  1263.             
  1264.         case T_LISTEN:
  1265. //
  1266. // You are the answering router and a connect request
  1267. // has been received.
  1268. //
  1269.             if (errno)
  1270.             {        
  1271.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1272.                 DOXTIDISCONNECT(myVarsPtr);
  1273.                 if(try_reconnect(myVarsPtr)) 
  1274.                     CONNDONE( -1 );
  1275.                 break;
  1276.             }
  1277.             
  1278.             if(get_listen( myVarsPtr ))
  1279.             {        
  1280.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1281.                 DOXTIDISCONNECT(myVarsPtr);
  1282.                 if(try_reconnect(myVarsPtr)) 
  1283.                     CONNDONE( -1 );
  1284.                 break;
  1285.             }
  1286.                 
  1287.             break;
  1288.             
  1289.         case T_DATA:
  1290. //
  1291. // Data has been received.
  1292. //
  1293.             if (errno)
  1294.             {        
  1295.                 (*myVarsPtr->AURPDispatch)(kAURPLogMsg, myVarsPtr->AURPRefNum, 0, myGlobals->logStr[kConnDownLogIx]);
  1296.                 DOXTIDISCONNECT(myVarsPtr);
  1297.                 if(try_reconnect(myVarsPtr)) 
  1298.                     CONNDONE( -1 );
  1299.                 break;
  1300.             }
  1301.             
  1302.             if (myVarsPtr->rcvBufAvail || myGlobals->waitMoreData) {
  1303.                 get_data( myVarsPtr );
  1304.             } else {
  1305.                 myVarsPtr->rcvPktsWaiting++;
  1306.             }
  1307.             break;
  1308.             
  1309.         default:
  1310.             DOXTIDISCONNECT(myVarsPtr);
  1311.         
  1312.             if(try_reconnect(myVarsPtr)) 
  1313.                 CONNDONE( -1 );
  1314.             
  1315.             break;
  1316.     }
  1317.  
  1318.     return;
  1319. }
  1320.  
  1321. /************************/
  1322. /*     Bin2Ascii            */
  1323. /************************/
  1324. static void Bin2Ascii(unsigned char *bin, unsigned char len, unsigned char *ascii)
  1325. {
  1326.     unsigned char cnt;
  1327.  
  1328.     for (cnt = 0; cnt < len; cnt++) {
  1329.         if (cnt & 0x01) {
  1330.             ascii[cnt] = bin[cnt >> 1] & 0x0F;
  1331.         } else {
  1332.             ascii[cnt] = bin[cnt >> 1] >> 4;
  1333.         }
  1334.         
  1335.         
  1336.         
  1337.         if (ascii[cnt] >= 0x0A && ascii[cnt] <= 0x0F) {
  1338.             ascii[cnt] +=  'A';
  1339.         } 
  1340.         else {
  1341.             ascii[cnt] +=  '0';
  1342.         } 
  1343.  
  1344.     }
  1345.     return;
  1346. }